package com.feiwei.hotitem

import org.apache.flink.api.scala.{DataSet, ExecutionEnvironment}
import org.apache.flink.streaming.api.scala.DataStream
import org.apache.flink.streaming.runtime.streamrecord.StreamElement
import org.apache.flink.table.api.Table
import org.apache.flink.table.api.scala.StreamTableEnvironment

object Test {

  def main(args: Array[String]): Unit = {


    val en = ExecutionEnvironment.getExecutionEnvironment

    val text: DataSet[String] = en.readTextFile("E:\\repository\\company\\myself\\flink-learning\\flink-learing-user-behavior-analysis\\HotItemsAnalysis\\src\\main\\resources\\text")

    val res: DataSet[String] = text.filter(c=> !"flink".equals(c))

    res.print()
  //  en.execute()



   val  t=StreamTableEnvironment.create()

  }

}
